package io.task.message.socket.spi.client;

import io.task.message.socket.Node;
import lombok.Getter;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;

import java.nio.channels.AsynchronousSocketChannel;
import java.util.concurrent.CountDownLatch;

@Slf4j
@Setter
@Getter
public class ConnectionCompletionVo {

    private ClientChannelContext channelContext = null;

    private Client client = null;

    private boolean isReconnect = false;

    private AsynchronousSocketChannel asynchronousSocketChannel;

    private Node serverNode;

    private String bindIp;

    private Integer bindPort;

    private CountDownLatch countDownLatch = null;


    public ConnectionCompletionVo(ClientChannelContext channelContext, Client client, boolean isReconnect, AsynchronousSocketChannel asynchronousSocketChannel,
                                  Node serverNode, String bindIp, Integer bindPort) {
        super();
        this.channelContext = channelContext;
        this.client = client;
        this.isReconnect = isReconnect;
        this.asynchronousSocketChannel = asynchronousSocketChannel;
        this.serverNode = serverNode;
        this.bindIp = bindIp;
        this.bindPort = bindPort;
    }


}
